package priv.bestbeat.reportcenter.core.mq;

/**
 * @author 张渠钦
 * @date 2022/4/24 17:57
 * @param <T> 消息
 */
public interface MessageHandleable<T> {


    /**
     * 发送消息
     * @param message 发送的消息
     * @return T 发送的消息
     * @throws Exception
     */
    T send(T message) throws Exception;

    /**
     * 发送消息并监控
     * @param message 发送的消息
     * @return T 发送的消息
     */
    T sendWithMonitor(T message) throws Exception;

}
